package cn.xinfei.xdecision.data.core.frame.dispatch;

import cn.xinfei.xdecision.common.model.datax.enums.CollectStageEnum;
import com.alibaba.fastjson.JSONObject;

import java.util.List;
import java.util.Map;
import java.util.Set;

public interface ExecutorDispatch {
    void dispatch(String requestId,
                  Set<String> varCodes,
                  JSONObject inputPrarams,
                  Map<String, Set<String>> executorAndVarCodesMap,
                  Map<String, Set<String>> varDependParamMap,
                  Map<String, Object> dispatchResult,
                  CollectStageEnum collectStageEnum);
}
